package com.leo.util;

import org.java_websocket.WebSocket;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * @ClassName FXChatUtil
 * @Description
 * @Author wangss
 * @date 2021.11.26 22:13
 * @Version 1.0
 */
public class FXChatUtil {

    // 在线人数
    public static final AtomicInteger onlineCount = new AtomicInteger();

    // 存放登录用户的用户名和websocket信息
    public static final ConcurrentMap<String, WebSocket> webSocketPools = new ConcurrentHashMap<>();
}
